﻿//using System;
//using System.Collections.Concurrent;
//using System.Collections.Generic;
//using System.Linq;
//using System.Threading.Tasks;
//using System.Web;
//using Microsoft.AspNet.SignalR;

namespace TheHeGeo.DataTransfer
{
//    public class DataStream:Hub
//    {
//        public void Send(string name,string data, string message)
//        {
//            // Call the broadcastMessage method to update clients.
//            Clients.All.broadcastMessage(name,data, message);
//        }
//
//        public static ConcurrentDictionary<string, string> Dict = new ConcurrentDictionary<string, string>();
//
//        public void Notify(string name, string id)
//        {
//            Dict.TryAdd(name, id);
//        }
//
//        public void SendToSpecific(string message, string name)
//        {
//            Clients.Client(Dict[name]).broadcastMessage(message);
//        }
//
//        public override Task OnDisconnected()
//        {
//            string str;
//            var key = Dict.Keys.FirstOrDefault(p => Dict[p].Equals(Context.ConnectionId));
//            if(key!=null)
//                Dict.TryRemove(key, out str);
//            return base.OnDisconnected();
//        }
//    }
}